import pandas as pd

# 统一开户信息结构 (DataFrame columns)
ACCOUNT_INFO_COLUMNS = [
    '账号', '卡号','开户名', '开户行名称', '证件号码', '状态', '余额', '销户日期','销户前余额','手机号',
    '证件类型',  '账号类型', '币种', '开户日期', '开户网点'
]

# 统一流水信息结构 (DataFrame columns)
TRANSACTION_FLOW_COLUMNS = [
    '交易时间', '交易时间戳','交易流水号','交易账号','户名',
    '摘要/用途', '交易类型',  '金额', '币种', '余额',
    '对方户名', '对方账号', '对方开户行', '对方证件号',
    '交易渠道', '交易网点', '备注','备注2','交易状态'
]

def normalize_account_info(data_dict):
    """归一化开户信息为DataFrame"""
    df = pd.DataFrame([data_dict])  # 假设单行数据
    return df.reindex(columns=ACCOUNT_INFO_COLUMNS, fill_value=None)

def normalize_transaction_flow(data_list):
    """归一化流水信息为DataFrame"""
    df = pd.DataFrame(data_list)
    return df.reindex(columns=TRANSACTION_FLOW_COLUMNS, fill_value=None)